//package com.cnebula.dataprocess.sqoop.job;
//
//import org.apache.rocketmq.spring.starter.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.starter.core.RocketMQListener;
//import org.springframework.stereotype.Service;
//
//import com.cnebula.dataprocess.common.sqoop.SqoopJobMessage;
//import com.google.gson.Gson;
//
////@Service
////@RocketMQMessageListener(topic = "sqoop-job-topic", consumerGroup = "sqoop-job-consumer")
////public class SqoopJobMessageConsumer implements RocketMQListener<SqoopJobMessage> {
////
////	Gson gson = new Gson();
////
////	@Override
////	public void onMessage(SqoopJobMessage msg) {
////		System.out.println(gson.toJson(msg));
////	}
////}
